// 云函数入口文件
const cloud = require('wx-server-sdk')

cloud.init({
  env: cloud.DYNAMIC_CURRENT_ENV
})
// 数据库操作对象
const db = cloud.database()
const _ = db.command
// 云函数入口函数
exports.main = async (event, context) => {
 
  await db.collection('es_website').where({
    send_email:1
  }).update({
      data:{
        send_email:0
      }
  }).then(res=>{
    console.log('更新网点发送邮件状态成功');
    console.log(res);
  }).catch(err=>{
    console.log('更新网点发送邮件状态失败');
    console.log(err);
  })

  await db.collection('es_customer').where({
    ybcts: _.gt(0)
  }).update({
    data:{
      ybcts: _.inc(1)
    }
  }).then(res=>{
    console.log('更新保存天数成功');
    console.log(res);
  }).catch(err=>{
    console.log('更新保存天数失败');
    console.log(err);
  })

  // try {
  //   return await db.collection('es_customer').where({
  //     ybcts: 16
  //   }).remove()
  // } catch(e) {
  //   console.error(e)
  // }
}